package kafkastudy.spring;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.listener.MessageListener;

/**
 * Created by hp on 2017/9/30.
 */
public class KafkaConsumerConcurrentService implements MessageListener<String,String> {
    public void onMessage(ConsumerRecord<String, String> integerStringConsumerRecord) {
        System.out.println("get message :"+integerStringConsumerRecord.value());
    }
}
